package com.example.mq1.common;


import com.example.mq1.mqserver.core.BasicProperties;

import java.io.IOException;

@FunctionalInterface
public interface Consumer {

    /**
     * 提供一个回调函数，让消费者收到消息后进行处理
     *
     * @param consumerTag
     * @param basicProperties
     * @param body
     */
    void handlerDelivery(String consumerTag, BasicProperties basicProperties, byte[] body) throws IOException, MqException;

}
